#ifndef _HJ212_DATASTREAM_H
#define _HJ212_DATASTREAM_H

#include "hj212_client_def.h"



int get_hj212_datastream_state(struct hj212_datastream *stream);
int hj212_datastream_push(struct hj212_datastream *stream, hj212_client_t dst, int is_response);
struct hj212_datastream *hj212_datastream_create(struct hj212_client *client, int type, struct hj212_datasource *source);
void hj212_datastream_delete(struct hj212_client *client, struct hj212_datastream *stream);





#endif
